/*
 * Copyright (C) 2019 yixun All Rights Reserved.
 * 
 * ReportModelServiceImpl.java
 */
package com.yixun.qfbao.service.impl;

import com.yixun.common.page.Page;
import com.yixun.qfbao.mapper.ReportModelMapper;
import com.yixun.qfbao.model.ReportModel;
import com.yixun.qfbao.model.dto.ReportModelDto;
import com.yixun.qfbao.model.enums.DefaultReportModelEnum;
import com.yixun.qfbao.model.enums.DelFlagEnum;
import com.yixun.qfbao.service.ReportModelService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.Calendar;
import java.util.List;
import java.util.Map;
import java.util.function.Function;
import java.util.stream.Collectors;


/**
 * [文件名称]<br>
 * ReportModelServiceImpl.java<br>
 * <br>
 * [文件描述]<br>
 *  service interface impl<br>
 * <br>
 * [修改记录]<br>
 * 2019-03-04 11:02:03 创建 陶俊代码生成器<br>
 * 
 * @author 陶俊代码生成器
 * @version 1.00
 */
@Service("reportModelService")
public class ReportModelServiceImpl implements ReportModelService {
	
	@Autowired
	private ReportModelMapper mapper;
	
	/**
	 * @param entity 搜索条件
	 * @param begin 分页开始行数[不包含]
	 * @param end 分页结束行数[包含]
	 * @return 分页记录
	 */
	@Transactional(readOnly = true)
	public Page<ReportModel> getPageModel(ReportModelDto entity,int begin,int end){
		Integer total = mapper.count(entity);
		List<ReportModel> rows = mapper.list(entity,begin,end);
	    Page<ReportModel> msr = new Page<ReportModel>(total, rows);
		return msr;
	}

	/**
	 * 查询列表
	 * @param entity 搜索条件
	 * @return 分页记录
	 */
	public List<ReportModel> selectListByDto(ReportModelDto entity){
		return mapper.selectListByDto(entity);
	}
	
	/**
	 * 查询单个
	 * @param entity 搜索条件
	 * @return 分页记录
	 */
	public ReportModel selectByDto(ReportModelDto entity){
		return mapper.selectByDto(entity);
	}
	
	/**
	 * @param entity 搜索条件
	 * @return 分页记录
	 */
	public ReportModel selectById(Long id){
		if(id!=null){
			return mapper.selectById(id);
		}
		return null;
	}
	/**
	 * @param entity 新增记录的详细信息
	 * @return 新增行数
	 */
	@Transactional
	public ReportModelDto create(ReportModelDto entity) {
		ReportModelDto dto = new ReportModelDto();
		dto.setOrders(" t.model_order desc");
		dto.setPremisesId(entity.getPremisesId());
		dto.setDelFlag(DelFlagEnum.UNDEL.getNo());
		List<ReportModel> list = mapper.selectListByDto(dto);
		if(list != null && list.size() > 0){
			entity.setModelOrder(list.get(0).getModelOrder() + 1L);
		}else{
			entity.setModelOrder(1L);
		}
		entity.setCreateTime(Calendar.getInstance().getTime());
		mapper.add(entity);
		return entity;
	}

	/**
	 * @param entity 更新记录的详细信息
	 * @return 更新行数
	 */
	public int update(ReportModelDto entity) {
		entity.setUpdateTime(Calendar.getInstance().getTime());
		return mapper.edit(entity);
	}
    
	/**
	 * @param entity 待删除的记录信息
	 * @return 删除行数
	 */
	public int destroy(ReportModelDto entity) {
		return mapper.del(entity);
	}
	
	/**
	 * @param entity 新增或更新
	 * @return 新增行数
	 */
	public int saveOrUpdate(ReportModelDto entity) {
		if(entity!=null&&entity.getId()!=null){
			return update(entity);
		}else{
			create(entity);
			return 1;
		}
	}
	
	/**
	 * @param entity 根据pojo搜索如果主键为空则返回它本身
	 * @return 一行记录或本身
	 */
	@Override
	public ReportModel selectBy(ReportModel entity) {
		if(entity!=null&&entity.getId()!=null){
			return mapper.selectById(entity.getId());
		}
		return entity;
	}
	@Override
	public ReportModel editReportModel(ReportModelDto entity){
		if(entity!=null&&entity.getId()!=null){
			update(entity);
			return entity;
		}else{
			return create(entity);
		}
	}

	/**
	 * 批量更新楼盘报备模板
	 * @param sourceId
	 * @param premisesIds
	 */
	@Override
	public void batchUpdateReportModel(Long sourceId,List<Long> premisesIds){
		//获取样品模板
		ReportModelDto dto = new ReportModelDto();
		dto.setDelFlag(DelFlagEnum.UNDEL.getNo());
		dto.setPremisesId(sourceId);
		List<ReportModel> list = mapper.selectListByDto(dto);
		Map<String,ReportModel> map = list.stream().collect(Collectors.toMap(ReportModel::getModelColumn, Function.identity()));
		//更新当前模板
		updateReportModel(map,sourceId);
		//批量更新模板
		for(Long premisesId : premisesIds){
			if(sourceId.compareTo(premisesId) == 0 ){
				continue;
			}
			updateReportModel(map,premisesId);
		}
	}

	/**
	 * 更新单个楼盘的报备模板
	 * @param sourceMap
	 * @param premisesId
	 */
	@Override
	public void updateReportModel(Map<String,ReportModel> sourceMap,Long premisesId){
		ReportModelDto dto = new ReportModelDto();
		dto.setDelFlag(DelFlagEnum.UNDEL.getNo());
		dto.setPremisesId(premisesId);
		List<ReportModel> list = mapper.selectListByDto(dto);
		Map<String,ReportModel> targetMap = list.stream().collect(Collectors.toMap(ReportModel::getModelColumn,Function.identity()));
		if(list != null && list.size() > 0){
			//更新已有报备模板
			for(ReportModel rm : list){
				if(sourceMap.containsKey(rm.getModelColumn())){
					// 暂定预计到访时间、报备推荐人两个模板字段定制
					if(DefaultReportModelEnum.VISIT_TIME.getModelColumn().equals(rm.getModelColumn())
					|| DefaultReportModelEnum.RECOMMENDER.getModelColumn().equals(rm.getModelColumn())){
						rm.setShowFlag(sourceMap.get(rm.getModelColumn()).getShowFlag());
					}
					rm.setModelAlias(rm.getModelAlias());
					mapper.edit(rm);
				}else{
					rm.setDelFlag(DelFlagEnum.DEL.getNo());
					mapper.edit(rm);
				}
			}
			//添加没有的报备模板
			for(ReportModel rm : sourceMap.values()){
				if(!targetMap.containsKey(rm.getModelColumn())){
					rm.setPremisesId(premisesId);
					mapper.add(rm);
				}
			}
		}else{
			//未添加过模板直接添加模板
			for(ReportModel rm : sourceMap.values()){
				rm.setPremisesId(premisesId);
				mapper.add(rm);
			}
		}

	}
}
